package org.lemon.transport.context.service.queue;

import org.lemon.transport.context.data.queue.message.QueueMessage;

public interface QueueProducer<T extends QueueMessage> {

    void init();

    String getDefaultTopic();

    void send(TopicPartitionInfo tpi, T msg, QueueCallback callback);

    void stop();
}
